package com.tn.serverredis.config;

import com.databstech.cache.redis.server.ReisReciverServer;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Primary;
import org.springframework.data.redis.connection.Message;
import org.springframework.stereotype.Component;

/**
 * @ClassName : MessageSave
 * @Description : redis订阅消息保存起来
 * @Author : tn
 * @Date: 2020-09-11 10:54
 */
@Component
@Slf4j
@Primary
public class MessageSave implements ReisReciverServer<String> {
    @Override
    public String subpubMessage(Message message) {
        log.info(message.toString());
        return null;
    }
}
